加多|底线_Python的线程14有界信号量，这是一个有底线的信号量

篇首语：本文由编程笔记#小编为大家整理，主要介绍了Python的线程14 有界信号量，这是一个有底线的信号量相关的知识，希望对你有一定的参考价值。

正式的Python专栏第51篇&＃xff0c;同学站住&＃xff0c;别错过这个从0开始的文章&＃xff01;

前篇学委提出了Semaphore信号量来制作限流器的思路和一个简单的限流器实现。

代码运行起来了&＃xff0c;看起来没有错误。

不过&＃xff0c;细心的读者会发现&＃xff0c;如果我们出现像下面的信号量使用方式&＃xff1a;

xuewei_semaphore.acquire() #获取信号量
//do something
....
xuewei_semaphore.release() #释放信号量
#>>> xuewei_semaphore.release() #如果这里再调用一次release呢&＃xff1f;

也就是 Semaphore 进行的释放的操作&＃xff0c;比获取的还多一点点&＃xff0c;会不会出问题&＃xff1f;

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# &＃64;Time : 2021/11/27 10:43 下午
# &＃64;Author : LeiXueWei
# &＃64;CSDN/Juejin/Wechat: 雷学委
# &＃64;XueWeiTag: CodingDemo
# &＃64;File : thread_semaphore_boundvs_unbound.py
# &＃64;Project : hello
import threading
import time
xuewei_semaphore &＃61; threading.Semaphore(1) #后面改成有界信号量
print("xuewei_semaphore:", xuewei_semaphore)
def run():
print(" %s ready" % threading.current_thread().name)
xuewei_semaphore.acquire()
print(" %s go" % threading.current_thread().name)
time.sleep(0.1)
print(" %s completed" % threading.current_thread().name)
xuewei_semaphore.release()
def abnormal_run():
run()
xuewei_semaphore.release() # 多release了一次
t &＃61; threading.Thread(name&＃61;"正常使用信号量", target&＃61;run)
t.start()
time.sleep(1)
t &＃61; threading.Thread(name&＃61;"非正常使用信号量", target&＃61;abnormal_run)
t.start()


上面学委结合了第一篇分享信号量的文章&＃xff0c; 简化了一下&＃xff0c;重点展示多释放信号量的效果。

我们发现程序没有任何报错&＃xff1a;

如果我们把反常的使用增加调用呢&＃xff0c;比如下面的代码&＃xff1a;

#在上方代码后面加上下面这段代码
for i in range(10000):
t &＃61; threading.Thread(name&＃61;"非正常使用信号量"&＃43;str(i), target&＃61;abnormal_run)
t.start()


全程没有报错&＃xff01;&＃xff01;&＃xff01;

我直接震惊了&＃xff01;Python容错率太高了&＃xff08;这是高情商的说法&＃xff0c;&＃x1f602;&＃xff09;

threading.BoundedSemaphore 这个类就是有界信号量&＃xff0c;英文名非常直观了。

什么是有界&＃xff1f;

跟做人一样&＃xff0c;守住底线。那么Semaphore的底线在哪里&＃xff1f;我们可以点击这个类去看一部分代码。

Semaphore维护了一个_value, 有界的信号量其实就是加多了一个变量_initial_value&＃xff0c;去记录了信号量初始值。

后续&＃xff0c;我们调用release函数的时候&＃xff0c;有界信号量&＃xff0c;每次都会检查&＃xff0c;_value是否越界了&＃xff08;就是一旦超过了_initial_value&＃xff0c;就抛出一个ValueError&＃xff0c;提示越界了&＃xff01;&＃xff09;

这个太友好了.

下面就使用有界信号量展示&＃xff0c;对比第一段代码&＃xff0c;仅仅把

xuewei_semaphore &＃61; threading.Semaphore(1)

改为了&＃xff1a;

xuewei_semaphore &＃61; threading.BoundedSemaphore(1)

所以读者可以直接改&＃xff0c;当然也可以选择直接复制下面的代码再存一个文件运行。

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# &＃64;Time : 2021/11/27 10:43 下午
# &＃64;Author : LeiXueWei
# &＃64;CSDN/Juejin/Wechat: 雷学委
# &＃64;XueWeiTag: CodingDemo
# &＃64;File : thread_semaphore_boundvs_unbound3.py
# &＃64;Project : hello
import threading
import time
xuewei_semaphore &＃61; threading.BoundedSemaphore(1)
print("xuewei_semaphore:", xuewei_semaphore)
def run():
print(" %s ready" % threading.current_thread().name)
xuewei_semaphore.acquire()
print(" %s go" % threading.current_thread().name)
time.sleep(0.1)
print(" %s completed" % threading.current_thread().name)
xuewei_semaphore.release()
def abnormal_run():
run()
xuewei_semaphore.release() # 多release了一次
t &＃61; threading.Thread(name&＃61;"正常使用信号量", target&＃61;run)
t.start()
time.sleep(1)
t &＃61; threading.Thread(name&＃61;"非正常使用信号量", target&＃61;abnormal_run)
t.start()


使用有界之后&＃xff0c;果然&＃xff0c;过度释放&＃xff0c;系统就报错了&＃xff01;终于放心了。

大家应该尽量使用有界信号量&＃xff0c;它能帮我们守住边界。它不会因为我们不小心写错程序&＃xff0c;写多一次release而放任程序继续正常运行。&＃xff08;可能是熬夜写代码&＃xff0c;建议不要&＃xff01;写代码需要一个舒适的状态&＃xff0c;质量更高&＃xff09;

如果使用纯Semaphore&＃xff0c;那请务必封装起来&＃xff08;成对调用封闭起来&＃xff09;不对外开放acquire和release的使用&＃xff0c;这样才能安装。

喜欢Python的朋友&＃xff0c;请关注学委的 Python基础专栏 or Python入门到精通大专栏

持续学习持续开发&＃xff0c;我是雷学委&＃xff01;
编程很有趣&＃xff0c;关键是把技术搞透彻讲明白。
欢迎关注微信&＃xff0c;点赞支持收藏!